package com.cpr.demo.mycraft.mq.redis;

/**
 * @author Chen Panrui
 * created at 2021/10/9 13:52
 */
public interface RedisMessageQueueManager {

    /**
     * 发送消息
     * {@link com.cpr.demo.mycraft.mq.redis.single.SingleRedisMessageQueueManagerImpl} 使用 该实现类 发布消息 只会被 消费一次
     * @param queue 某个队列名称
     * @param message 消息体
     */
    void publish(String queue, RedisMessage message);

    /**
     * 订阅
     * @param queue 队列名
     * @param handler 消费处理的逻辑
     */
    void subscribe(String queue, MessageHandler handler);

}
